package cn.xenosp.server.common.sse;

import cn.xenosp.server.common.MessageTypeEeum;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Date;

/**
 * 项目名： service-web
 * 包路径： cn.xenosp.server.common.sse
 * 作者：   TongHui
 * 创建时间: 2024-12-20 18:14
 * 描述: 心跳任务
 * 版本: 1.0
 */
public class HeartBeatTask implements Runnable{
    private static final Logger logger = LoggerFactory.getLogger(HeartBeatTask.class);

    private final SseVO sse;

    public HeartBeatTask(SseVO sse) {
        // 这里可以按照业务传入需要的数据
        this.sse = sse;
    }

    @Override
    public void run() {
        logger.info("SSE 心跳检测 | ID: {} | Date: {}", sse.getUid(), new Date());
        SseSession.send(sse.getUid(), MessageTypeEeum.ping);
    }
}
